package com.kokomi.topic_model;


import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;


/**
 * 生产者
 * 主题模型，
 * # 表示可以匹配零个或多个单词
 * * 只能匹配一个词
 * 举例：
 * a.# 能够匹配：a.b.c 或者 a.b.c.d
 * a.* 只能匹配：a.b 无法匹配 a.b.c
 * 本次测试routingKey 为 china.# 和 #.news
 */
@RestController
@Slf4j
public class TopicProducer {


    @Autowired
    private RabbitTemplate rabbitTemplate;


    @GetMapping("/topicModel")
    public ResponseEntity<?> topicModel(String msg , String routingKey) {
        log.info("生产者主题消息：{}", msg);
        rabbitTemplate.convertAndSend("topic_exchange", routingKey, msg);
        return ResponseEntity.ok("消息发送成功");
    }



}
